package kevin.bigdata.spark.test

/**
 * @author: kevin  
 * @date: 21:52 2021/4/29
 */
class SubTask extends Serializable {
  var datas: List[Int] = _

  var logic: (Int)=>Int = _

  //计算
  def compute() = {
    datas.map(logic)
  }
}
